package com.shujia.hdfs;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.LocatedFileStatus;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.RemoteIterator;

import java.io.IOException;

public class Demo01GetConn {
    public static void main(String[] args) throws IOException {
        // 建立HDFS的连接：建立namenode的连接
        // 连接地址：hdfs://master:9000/

        // 创建Hadoop配置文件
        Configuration conf = new Configuration();
        // 设置Name Node地址
        conf.set("fs.defaultFS", "hdfs://master:9000/");

        FileSystem fs = FileSystem.get(conf);

        // listFiles ：列出指定目录下的所有文件（不是目录）
        RemoteIterator<LocatedFileStatus> files = fs.listFiles(new Path("/"), true);


        while (files.hasNext()) {
            LocatedFileStatus file = files.next();
            long accessTime = file.getAccessTime();
            String name = file.getPath().getName();

            System.out.println(file.getPath().getParent().getName());

            System.out.println(name + "," + accessTime);
        }
    }
}
